package com.j.lemon.learn.pulsar;

import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api.MessageListener;

public class ListenerTest implements MessageListener<String> {
    @Override
    public void received(Consumer consumer, Message msg) {

    }
}
